package org.rrd.kafka.phoneix.db;

import org.apache.flink.configuration.Configuration;
import org.apache.flink.streaming.api.functions.sink.RichSinkFunction;

/**
 * @program: dataStreming
 * @description:
 * @author: sunteng
 * @create: 2020-02-27 09:37
 **/
public class MysqlJdbc extends RichSinkFunction {
    @Override
    public void open(Configuration parameters) throws Exception {
        super.open(parameters);
    }

    @Override
    public void close() throws Exception {
        super.close();
    }

    @Override
    public void invoke(Object value, Context context) throws Exception {

    }
}
